package com.microlearning.common.rabbitmq.consumer;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

/**
 * Fanout(广播)交换机：将消息交给所有绑定到交换机的队列
 * 总结(交换机作用)：
 *      1、接收publisher发送的消息
 *      2、将消息按照路由规则到与之绑定的队列
 *      3、不能缓存消息，路由失败则消息丢失
 *      4、FanoutExchange会将消息路由到每个绑定的队列
 */
@Service
public class FanoutConsumer {

    /**
     * 获取队列消息
     */
    @RabbitListener(queues = "mic.fanout.queue1")
    public String pullMessageQueue1(String message) {
        return message;
    }
    /**
     * 获取队列消息
     */
    @RabbitListener(queues = "mic.fanout.queue2")
    public String pullMessageQueue2(String message) {
        return message;
    }

}
